import pymysql

#获取连接
def get_conn():
    try:  # 使用try except来捕获异常，防止程序乱
        db = pymysql.connect(host="localhost", user="root", passwd="", database="dbxx",charset="utf8")  # 使用pymysql.connect来连接
        return db
    except pymysql.Error:  # 不成功的话用except捕获一下pymysql的错误类型
        print("数据库连接异常")    # 打印一下错误类型

#关闭连接
def close_conn(cursor,db):
    try:
        if cursor:
            cursor.close()
        if db:
            db.close()
    except pymysql.Error as e:
        print('数据库关闭失败' + str(e))
    finally:
        cursor.close()
        db.close()
print(get_conn())
